package cn.bytengine.stem.cluster.netty;

import cn.bytengine.stem.sdso.ClusterMessageHandler;
import cn.bytengine.stem.contexts.Context;

public class NettyClusterHostServerFactory implements ClusterHostServerFactory {
    @Override
    public ClusterHostServer newServer(Context context, ClusterMessageHandler clusterMessageHandler) throws Exception {
        ClusterHostServer clusterHostServer = new NettyClusterHostServer(
                new ClusterHostNettyTcpServer(context),
                new ClusterHostNettyMulticastUdpServer(context));
        clusterHostServer.startup(context);
        return clusterHostServer;
    }
}
